package cn.getech.data.development.service;

import cn.getech.data.development.dto.JobInfoDto;
import cn.getech.data.development.dto.JobLinkDto;
import cn.getech.data.development.entity.WorkFlowDep;
import com.baomidou.mybatisplus.extension.service.IService;

import java.util.List;

public interface WorkFlowDepService extends IService<WorkFlowDep> {

    List<Integer> selectJobIdsByProcId(Integer procId);
    /**
     * 获取用户授权项目下所有任务
     * @return
     */
    List<Integer> selectJobIds();

    void initWorkFlowDepHistory(List<JobLinkDto> jobLinks, List<JobInfoDto> jobInfos, String confParams, Integer workFlowDepId, String oozieJobId, int runType, String queueName);

    void stopAllJobAndJobNodeHistoryByWorkFlowLay(Long workDlowDepId, String lastOOziedId, String lastCorOozieId);
}
